/*
授权声明：
本源码系《Java多线程编程实战指南（设计模式篇）》一书（ISBN：978-7-121-27006-2，以下称之为“原书”）的配套源码，
欲了解本代码的更多细节，请参考原书。
本代码仅为原书的配套说明之用，并不附带任何承诺（如质量保证和收益）。
以任何形式将本代码之部分或者全部用于营利性用途需经版权人书面同意。
将本代码之部分或者全部用于非营利性用途需要在代码中保留本声明。
任何对本代码的修改需在代码中以注释的形式注明修改人、修改时间以及修改内容。
本代码可以从以下网址下载：
https://github.com/Viscent/javamtp
http://www.broadview.com.cn/27006
*/

package mtpattern.ch12.ms.example;


import mtpattern.ch12.ms.RetryInfo;
import mtpattern.ch12.ms.SubTaskFailureException;
import util.Debug;

import java.math.BigInteger;
import java.util.Set;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;

public class ExceptionHandlingExample {

	public void handle(ExecutionException e, Set<BigInteger> result) {
		Throwable cause = e.getCause();
		if (SubTaskFailureException.class.isInstance(cause)) {

			@SuppressWarnings("rawtypes")
			RetryInfo retryInfo = ((SubTaskFailureException) cause).retryInfo;

			Object subTask = retryInfo.subTask;
			Debug.info("retrying subtask:" + subTask);

			@SuppressWarnings("unchecked")
			Callable<Set<BigInteger>> redoCmd = retryInfo.redoCommand;
			try {
				result.addAll(redoCmd.call());
			} catch (Exception exception) {
				exception.printStackTrace();
			}
		}
	}

}
